package com.wpp.concurrent.container;

import java.util.concurrent.ArrayBlockingQueue;

/**
 * @description:
 * @author: WangPengPeng
 * @create: 2021-11-13 22:03
 **/
public class BlockingQueueTest {


    public static void main(String[] args) {
        ArrayBlockingQueue<Integer> arrayBlockingQueue = new ArrayBlockingQueue<>(2);

        arrayBlockingQueue.offer(1);
        arrayBlockingQueue.add(2);

        System.out.println(arrayBlockingQueue.element());
    }

}
